package com.hongye.third.utils;

import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.model.*;
import com.hongye.common.constants.Constant;
import com.hongye.common.utils.ResponseResult;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;

import java.io.InputStream;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * @author my
 * @email 2148852429@qq.com
 * @date 2022/4/19
 * @time 15:27
 */
@Component
public class OssUtil {

    public ResponseResult<String> uploadFile(MultipartFile file) {
        ResponseResult<String> responseResult = new ResponseResult<>();
        try {
            // yourEndpoint填写Bucket所在地域对应的Endpoint。以华东1（杭州）为例，Endpoint填写为https://oss-cn-hangzhou.aliyuncs.com。
            String endpoint = "https://oss-cn-shanghai.aliyuncs.com";
            // 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。
            String accessKeyId = "LTAI5t5kZj7XVXyBHGKf69b9";
            String accessKeySecret = "C7DnyRT0COQDgLqDQfx3LlJI33nGqy";
            String baseUrl = "https://gulimall-1907a.oss-cn-shanghai.aliyuncs.com/";

            // 填写Bucket名称，例如examplebucket。
            String bucketName = "gulimall-1907a";
            //------------替换以上------------
            SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
            String format = simpleDateFormat.format(new Date());
            // 用户上传文件时指定的前缀。
            String dir = format+"/";
            // 填写Object完整路径，例如exampledir/exampleobject.txt。Object完整路径中不能包含Bucket名称。
            String objectName = dir+System.currentTimeMillis()+"_"+file.getOriginalFilename();
            OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);

            InitiateMultipartUploadRequest request = new InitiateMultipartUploadRequest(bucketName, objectName);

            InitiateMultipartUploadResult upresult = ossClient.initiateMultipartUpload(request);

            String uploadId = upresult.getUploadId();
            List<PartETag> partETags = new ArrayList<PartETag>();
            //1 MB。
            final long partSize = 1 * 1024 * 1024L;
            //文件大小
            Integer available = file.getInputStream().available();
            System.out.println(available);
            // final File sampleFile = new File("C:\\Users\\lcl\\Desktop\\上班\\js\\images\\f3.jpg");
            long fileLength = available.longValue();
            int partCount = (int) (fileLength / partSize);
            if (fileLength % partSize != 0) {
                partCount++;
            }

            for (int i = 0; i < partCount; i++) {
                long startPos = i * partSize;
                long curPartSize = (i + 1 == partCount) ? (fileLength - startPos) : partSize;
                InputStream instream = file.getInputStream();
                // 跳过已经上传的分片。
                instream.skip(startPos);
                UploadPartRequest uploadPartRequest = new UploadPartRequest();
                uploadPartRequest.setBucketName(bucketName);
                uploadPartRequest.setKey(objectName);
                uploadPartRequest.setUploadId(uploadId);
                uploadPartRequest.setInputStream(instream);
                // 设置分片大小。除了最后一个分片没有大小限制，其他的分片最小为100 KB。
                uploadPartRequest.setPartSize(curPartSize);
                // 设置分片号。每一个上传的分片都有一个分片号，取值范围是1~10000，如果超出此范围，OSS将返回InvalidArgument错误码。
                uploadPartRequest.setPartNumber(i + 1);
                // 每个分片不需要按顺序上传，甚至可以在不同客户端上传，OSS会按照分片号排序组成完整的文件。
                UploadPartResult uploadPartResult = ossClient.uploadPart(uploadPartRequest);
                // 每次上传分片之后，OSS的返回结果包含PartETag。PartETag将被保存在partETags中。
                partETags.add(uploadPartResult.getPartETag());
            }
            // 创建CompleteMultipartUploadRequest对象。
            // 在执行完成分片上传操作时，需要提供所有有效的partETags。OSS收到提交的partETags后，会逐一验证每个分片的有效性。当所有的数据分片验证通过后，OSS将把这些分片组合成一个完整的文件。
            CompleteMultipartUploadRequest completeMultipartUploadRequest =
                    new CompleteMultipartUploadRequest(bucketName, objectName, uploadId, partETags);

            CompleteMultipartUploadResult completeMultipartUploadResult = ossClient.completeMultipartUpload(completeMultipartUploadRequest);
            System.out.println(completeMultipartUploadResult.getETag());

            ossClient.shutdown();
            //成功
            responseResult.setSuccess(Constant.OssMsg.UPLOAD_SUCCESS);
            responseResult.setCode(Constant.OssMsg.UPLOAD_SUCCESS_CODE);
            responseResult.setMessage(Constant.OssMsg.UPLOAD_SUCCESS_MESSAGE);
            responseResult.setData(baseUrl+objectName);
            return responseResult;

        }catch (Exception e){
            e.printStackTrace();
            //失败
            responseResult.setSuccess(Constant.OssMsg.UPLOAD_ERROR);
            responseResult.setCode(Constant.OssMsg.UPLOAD_ERROR_CODE);
            responseResult.setMessage(Constant.OssMsg.UPLOAD_ERROR_MESSAGE);
            return responseResult;
        }

    }

}
